package aliyun

import (
	"context"

	"testkjcld.bhecard.com/gitlab/kit/esim/rocketmq/internal"

	mqhttpsdk "github.com/aliyunmq/mq-http-go-sdk"
)

type AliyunMQConsumer struct {
	mqhttpsdk.MQConsumer
}

// Start the PushConsumer for consuming message.
func (c *AliyunMQConsumer) Start() error {
	return nil
}

// Shutdown the PushConsumer, all offset of MessageQueue will be sync to broker before process exit.
func (c *AliyunMQConsumer) Shutdown() error {
	return nil
}

// Subscribe a topic for consuming.
func (c *AliyunMQConsumer) Subscribe(topic string, selector internal.MessageSelector,
	f func(context.Context, ...*internal.MessageExt) (internal.ConsumeResult, error)) error {
	return nil
}

// Unsubscribe a topic.
func (c *AliyunMQConsumer) Unsubscribe(topic string) error {
	return nil
}
